7cccf0ecee8b2d3ac654b73fb1b115de609524a0,ob1k-db/src/main/java/com/outbrain/ob1k/db/MySqlConnectionPool.java,MySqlConnectionPool,take,#,86
Before Change
}
private ComposableFuture<MySqlAsyncConnection> take() {
final ComposableFuture<MySQLConnection> connFuture = ScalaFutureHelper.from(new ScalaFutureHelper.FutureProvider<MySQLConnection>() {
@Override
public Future<MySQLConnection> provide() {
return _pool.take();
}
});
return connFuture.continueOnSuccess(new SuccessHandler<MySQLConnection, MySqlAsyncConnection>() {
@Override
public MySqlAsyncConnection handle(final MySQLConnection result) {
return new MySqlAsyncConnection(result);
}
});
}
private ComposableFuture<Boolean> giveBack(final MySqlAsyncConnection conn) {
After Change
}
private ComposableFuture<MySqlAsyncConnection> take() {
final ComposableFuture<MySQLConnection> connFuture = ScalaFutureHelper.from(_pool::take);
return connFuture.continueOnSuccess((SuccessHandler<MySQLConnection, MySqlAsyncConnection>) MySqlAsyncConnection::new);
}
private ComposableFuture<Boolean> giveBack(final MySqlAsyncConnection conn) {